package com.wicket.okrapp.biz.service.impl;

import cn.hutool.core.bean.BeanUtil;
import com.wicket.okrapp.biz.service.dto.req.*;
import com.wicket.okrapp.biz.service.dto.res.*;
import com.wicket.okrapp.common.util.CommonFunctionHelper;
import com.wicket.okrapp.common.util.RedisUtil;
import java.util.List;
import java.util.stream.Collectors;
import javax.annotation.Resource;
import org.apache.skywalking.apm.toolkit.trace.Tag;
import org.apache.skywalking.apm.toolkit.trace.Tags;
import org.apache.skywalking.apm.toolkit.trace.Trace;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.wicket.okrapp.base.service.MOmsEvaBatchRelatedSetService;

import java.util.concurrent.Callable;
import com.wicket.okrapp.common.exception.Assert;
import com.wicket.okrapp.biz.service.nb.NbCommunication;
import com.wicket.okrapp.base.service.MOmsVirtualOrgMemberService;
import com.wicket.okrapp.dal.po.mbg.OmsVirtualOrgMember;
import com.wicket.okrapp.base.service.dto.req.QueryMsgSendVirtualOrgMemberListReq;
import com.wicket.okrapp.base.service.dto.common.VirtualOrgMemberDto;
import com.wicket.okrcomponent.integration.dto.ImplementManyFieldsDataSetDuplicateRemovalComRespDto;
import com.wicket.okrcomponent.integration.dto.ImplementManyFieldsDataSetDuplicateRemovalComReqDto;
import com.wicket.okrcomponent.integration.dto.DataSetDuplicateRemovalDto;
import com.wicket.okrcomponent.integration.dto.ImplementInitSingleEvaTempMsgLocQtyComRespDto;
import com.wicket.okrcomponent.integration.dto.ImplementInitSingleEvaTempMsgLocQtyComReqDto;
import java.util.ArrayList;

import cn.hutool.core.collection.CollectionUtil;
import com.wicket.okrcomponent.integration.FwCompInterfaceModeClient;
import com.wicket.okrcomponent.integration.FwCompMessageClient;
import com.wicket.okrcomponent.integration.dto.QueryMessageDetailComRespDto;
import com.wicket.okrcomponent.integration.dto.QueryMessageDetailComReqDto;
import com.wicket.okrframework.integration.dto.QueryInductionRecordInfoDetailComRespDto;
import com.wicket.okrframework.integration.dto.QueryInductionRecordInfoDetailComReqDto;
import com.wicket.okrcomponent.integration.dto.GenerateSemanticInstanceStoryComRespDto;
import com.wicket.okrcomponent.integration.dto.GenerateSemanticInstanceStoryComReqDto;
import com.wicket.okrcomponent.integration.dto.QueryChannelDetailComRespDto;
import com.wicket.okrcomponent.integration.dto.QueryChannelDetailComReqDto;
import com.wicket.okrframework.integration.dto.ObtainOrgMemberMsgReceiveInfoComRespDto;
import com.wicket.okrframework.integration.dto.ObtainOrgMemberMsgReceiveInfoComReqDto;
import com.wicket.okrcomponent.integration.dto.ImplementSendChannelMessageComRespDto;
import com.wicket.okrcomponent.integration.dto.ImplementSendChannelMessageComReqDto;
import com.wicket.okrcomponent.integration.dto.ImplementShareIdeasDeleteBackComRespDto;
import com.wicket.okrcomponent.integration.dto.ImplementShareIdeasDeleteBackComReqDto;
import com.wicket.okrframework.integration.FwBaseInductionRecordClient;
import com.wicket.okrcomponent.integration.FwCompTemplateEngineClient;
import com.wicket.okrframework.integration.FwBaseMessageClient;
import com.wicket.okrcomponent.integration.FwCompCommunicationClient;
import com.wicket.okrapp.base.service.MOmsEvaluationObjectTargetCycleService;
import com.wicket.okrframework.integration.dto.QueryInductionRecordDetailComBorderRespDto;
import com.wicket.okrframework.integration.dto.QueryInductionRecordDetailComBorderReqDto;
import com.wicket.okrcomponent.integration.dto.ImplementFullSceneTwoPersonConversationComRespDto;
import com.wicket.okrcomponent.integration.dto.ImplementFullSceneTwoPersonConversationComReqDto;
import com.wicket.okrapp.biz.service.MessageService;
import com.wicket.okrframework.integration.dto.QueryDeptDetailComBorderRespDto;
import com.wicket.okrframework.integration.dto.QueryDeptDetailComBorderReqDto;
import com.wicket.okrframework.integration.dto.QuerySubordinateDeptTreeListComBorderRespDto;
import com.wicket.okrframework.integration.dto.QuerySubordinateDeptTreeListComBorderReqDto;
import com.wicket.okrframework.integration.dto.ImplementDeptInductionComRespDto;
import com.wicket.okrframework.integration.dto.ImplementDeptInductionComReqDto;
import com.wicket.okrframework.integration.FwBaseOrgClient;

/**
 * @author ：
 * @date ：
 *
 *
 * @version 1.0
 */
@Service
public class CommunicationServiceImpl
  implements com.wicket.okrapp.biz.service.CommunicationService {

  @Resource
  private RedisUtil redisUtil;
//@Resource
 //private MCustomFields4Service mCustomFields4Service;
//@Resource
 //private undefinedService undefinedService;
@Resource
  private MOmsEvaBatchRelatedSetService mOmsEvaBatchRelatedSetService;
@Resource
  private NbCommunication nbCommunication;
@Resource
  private MOmsVirtualOrgMemberService mOmsVirtualOrgMemberService;
@Resource
  private FwCompInterfaceModeClient fwCompInterfaceModeClient;
@Resource
  private FwCompMessageClient fwCompMessageClient;
@Resource
  private FwBaseInductionRecordClient fwBaseInductionRecordClient;
@Resource
  private FwCompTemplateEngineClient fwCompTemplateEngineClient;
@Resource
  private FwBaseMessageClient fwBaseMessageClient;
@Resource
  private FwCompCommunicationClient fwCompCommunicationClient;
@Resource
  private MOmsEvaluationObjectTargetCycleService mOmsEvaluationObjectTargetCycleService;
//@Resource
 //private MOmsMessageService mOmsMessageService;
@Resource
  private MessageService messageService;
@Resource
  private FwBaseOrgClient fwBaseOrgClient;
/**
   * D3-执行异步初始化单个评价模板位置消息数量(公共)[8361]
   * gen by moon at 1/26/2024, 5:09:59 AM
   */
  @Trace(operationName = "D3-执行异步初始化单个评价模板位置消息数量(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementAsynSingleEvaTempMsgLocQtyComRespDto implementAsynSingleEvaTempMsgLocQtyCom(ImplementAsynSingleEvaTempMsgLocQtyComReqDto reqDto){
    
      
      //步骤0: M3执行第四接收字段（特殊方法） - implementFourthReceivingField
     //ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes = null;
    ImplementFourthReceivingFieldReqDto receptionServiceReq=new ImplementFourthReceivingFieldReqDto();
  if(reqDto!=null){
      receptionServiceReq.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1509459_1
    }
  
    /*M3-接收入参字段[8259]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq.getEvaluationTemplateId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-接收入参字段-冗余评价模板ID不能为空",false);
      receptionServiceRes = nbCommunication.implementFourthReceivingField(receptionServiceReq);
      
      
      
    
//步骤1: M3执行第四接收字段（特殊方法） - implementFourthReceivingField
     //ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes_1 = null;
    ImplementFourthReceivingFieldReqDto receptionServiceReq_1=new ImplementFourthReceivingFieldReqDto();
  receptionServiceReq_1.setCreateInductionId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecInductionRecordId());//CURRENT_INDUCTIONID//sourceId:1509257_1
receptionServiceReq_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1509258_1
receptionServiceReq_1.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1509259_1
  
    /*M3-约定当前就职记录等（用于推缓存）[8259]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_1.getCreateInductionId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-约定当前就职记录等（用于推缓存）-创建人就职记录ID不能为空",false);
Assert.isNull(receptionServiceReq_1.getSpaceId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-约定当前就职记录等（用于推缓存）-创建于空间ID不能为空",false);
Assert.isNull(receptionServiceReq_1.getAppId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-M3-约定当前就职记录等（用于推缓存）-创建于联盟应用ID不能为空",false);
      receptionServiceRes_1 = nbCommunication.implementFourthReceivingField(receptionServiceReq_1);
      
      
      
    
//步骤2: M3异步开始（特殊方法） - addAsynchronizationStart
     //ModelCode: asynchronizationStart
      ImplementFourthReceivingFieldRespDto finalReceptionServiceRes_ = receptionServiceRes_1;
      Callable<String> call = new Callable<String>() {

    @Override
    public String call() throws Exception {
        //执行方法
    
//步骤3: M3执行业务应用公共字段推送内存（特殊方法） - implementBizPublicFieldPushMemory
     //ModelCode: publicFieldCache
        ImplementBizPublicFieldPushMemoryRespDto publicFieldCacheRes = null;
    ImplementBizPublicFieldPushMemoryReqDto publicFieldCacheReq=new ImplementBizPublicFieldPushMemoryReqDto();
  if(finalReceptionServiceRes_ !=null){
      publicFieldCacheReq.setCreateInductionId(finalReceptionServiceRes_.getCreateInductionId());//SimpleFieldAssign//sourceId:1509461_1
publicFieldCacheReq.setSpaceId(finalReceptionServiceRes_.getSpaceId());//SimpleFieldAssign//sourceId:1509462_1
publicFieldCacheReq.setAppId(finalReceptionServiceRes_.getAppId());//SimpleFieldAssign//sourceId:1509463_1
    }
  
    /*M3执行业务应用公共字段推送内存（特殊方法）[4520]  用于定时任务执行时，获取定时任务执行所需的公共信息，存入缓存，供定时任务中虚拟用况使用 */
    Assert.isNull(publicFieldCacheReq.getCreateInductionId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-M3执行业务应用公共字段推送内存（特殊方法）-创建人就职记录ID 不能为空",false);
Assert.isNull(publicFieldCacheReq.getSpaceId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-M3执行业务应用公共字段推送内存（特殊方法）-创建于空间ID不能为空",false);
Assert.isNull(publicFieldCacheReq.getAppId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-M3执行业务应用公共字段推送内存（特殊方法）-创建于联盟应用ID不能为空",false);
      publicFieldCacheRes = nbCommunication.implementBizPublicFieldPushMemory(publicFieldCacheReq);
      
      
      
    
//步骤4: D3-执行初始化单个评价模板位置消息数量(公共) - implementSingleEvaTempMsgLocQtyCom
     ImplementSingleEvaTempMsgLocQtyComRespDto implementSingleEvaTempMsgLocQtyComRespDto = null;
    ImplementSingleEvaTempMsgLocQtyComReqDto implementSingleEvaTempMsgLocQtyComReqDto=new ImplementSingleEvaTempMsgLocQtyComReqDto();
  if(reqDto!=null){
      implementSingleEvaTempMsgLocQtyComReqDto.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1509067_1
    }
if(finalReceptionServiceRes_ !=null){
      implementSingleEvaTempMsgLocQtyComReqDto.setSpaceId(finalReceptionServiceRes_.getSpaceId());//SimpleFieldAssign//sourceId:1509068_1
    }
  
    /*D3-执行初始化单个评价模板位置消息数量(公共)[8356]   */
    Assert.isNull(implementSingleEvaTempMsgLocQtyComReqDto.getEvaluationTemplateId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-D3-执行初始化单个评价模板位置消息数量(公共)-冗余评价模板ID不能为空",false);
Assert.isNull(implementSingleEvaTempMsgLocQtyComReqDto.getSpaceId(),"D3-执行异步初始化单个评价模板位置消息数量(公共)-D3-执行初始化单个评价模板位置消息数量(公共)-创建于空间ID不能为空",false);
      implementSingleEvaTempMsgLocQtyComRespDto = implementSingleEvaTempMsgLocQtyCom(implementSingleEvaTempMsgLocQtyComReqDto)/*vcase invoke 同服务,同domain*/;
      
      
      
    
//步骤5: M3异步结束（特殊方法） - addAsynchronizationEnd
     //ModelCode: asynchronizationEnd
        return "";
    }
};
CommonFunctionHelper.asynExcute(call);
    
ImplementAsynSingleEvaTempMsgLocQtyComRespDto retData = new ImplementAsynSingleEvaTempMsgLocQtyComRespDto();
  
  

  
  
return retData;
  }
/**
   * D3-执行初始化单个评价模板位置消息数量(公共)[8356]
   * gen by moon at 1/26/2024, 5:02:52 PM
   */
  @Trace(operationName = "D3-执行初始化单个评价模板位置消息数量(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementSingleEvaTempMsgLocQtyComRespDto implementSingleEvaTempMsgLocQtyCom(ImplementSingleEvaTempMsgLocQtyComReqDto reqDto){
    
      
      //virtualUsage 3-6-02查评价模板下所有小圈子的负责人列表  60229
      List<OmsVirtualOrgMember> listOmsVirtualOrgMember =new ArrayList<>();
    QueryMsgSendVirtualOrgMemberListReq queryMsgSendVirtualOrgMemberListReq=new QueryMsgSendVirtualOrgMemberListReq();
  queryMsgSendVirtualOrgMemberListReq.setUseScene("TARGET_PLAN_SCENE");//sourceId:1507922_1_60229
queryMsgSendVirtualOrgMemberListReq.setIsPersonCharge("TRUE");//sourceId:1509559_1_60229
queryMsgSendVirtualOrgMemberListReq.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1507923_1_60229
if(reqDto!=null){
      queryMsgSendVirtualOrgMemberListReq.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1507928_1_60229
queryMsgSendVirtualOrgMemberListReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1507924_1_60229
    }
  
    /*3-6-02查评价模板下所有小圈子的负责人列表[8224]   */
    Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getUseScene(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-虚拟组织使用场景不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getIsPersonCharge(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-是否负责人不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getSubjectLifeCycle(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-主体生命周期不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getEvaluationTemplateId(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-归属对象ID不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq.getSpaceId(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的负责人列表-创建于空间ID不能为空",false);
      listOmsVirtualOrgMember = mOmsVirtualOrgMemberService.queryMsgSendVirtualOrgMemberList(queryMsgSendVirtualOrgMemberListReq)/*vcase invoke 本地 method 方法调用;*/;
      
      
      
//virtualUsage D2执行多字段数据集记录去重(公共)  60230
      ImplementManyFieldsDataSetDuplicateRemovalComRespDto implementManyFieldsDataSetDuplicateRemovalComRespDto = null;
    if(listOmsVirtualOrgMember !=null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember)&& listOmsVirtualOrgMember.size()>0 ){
          ImplementManyFieldsDataSetDuplicateRemovalComReqDto implementManyFieldsDataSetDuplicateRemovalComReqDto=new ImplementManyFieldsDataSetDuplicateRemovalComReqDto();
  if(listOmsVirtualOrgMember!= null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember)&&  listOmsVirtualOrgMember !=null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember)){
      implementManyFieldsDataSetDuplicateRemovalComReqDto.setDataSetDuplicateRemovalList(//objList-to-objLists
        listOmsVirtualOrgMember.stream().map(item -> {
      DataSetDuplicateRemovalDto elm = new DataSetDuplicateRemovalDto();
      elm.setCommPrimaryKey(item.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:296500_2_60230
elm.setCustomField1(item.getUserId());//SimpleFieldAssign//sourceId:296501_2_60230
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1507956_1_60230
    }
  
    /*D2执行多字段数据集记录去重(公共)[7323]   */
    
      implementManyFieldsDataSetDuplicateRemovalComRespDto = fwCompInterfaceModeClient.implementManyFieldsDataSetDuplicateRemovalCom(implementManyFieldsDataSetDuplicateRemovalComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
if((implementManyFieldsDataSetDuplicateRemovalComRespDto!= null&&  implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList() !=null && implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList().size()>0)) {
        //if(D2将所有小圈子的负责人及主管按身份人员去重(公共).数据集记录去重列表数据集条数 大于 0)  60231
        
//ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes = null;
    if(implementManyFieldsDataSetDuplicateRemovalComRespDto !=null){
          ImplementFourthReceivingFieldReqDto receptionServiceReq=new ImplementFourthReceivingFieldReqDto();
  if(implementManyFieldsDataSetDuplicateRemovalComRespDto!= null&&  implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList() !=null&& !CollectionUtil.isEmpty(implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList())){
      receptionServiceReq.setVirtualOrgMemberList(//objList-to-objLists
        implementManyFieldsDataSetDuplicateRemovalComRespDto.getDataSetDuplicateRemovalList().stream().map(item -> {
      VirtualOrgMemberDto elm = new VirtualOrgMemberDto();
      if(item!=null){
      elm.setOriginalRoleMemberId(item.getCommPrimaryKey());//SimpleFieldAssign//sourceId:296527_2_60232
elm.setUserId(item.getCustomField1());//SimpleFieldAssign//sourceId:296528_2_60232
    }
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508297_1_60232
    }
  
    /*M3用于接收数据集入参[8259]  用于特殊方法接收上游入参。 */
    
      receptionServiceRes = nbCommunication.implementFourthReceivingField(receptionServiceReq);
      
      
      
           }
//ModelCode: circulationCollections
        for (VirtualOrgMemberDto circulationCollectionsRes: receptionServiceRes.getVirtualOrgMemberList()){ 

ImplementInitSingleEvaTempMsgLocQtyComRespDto implementInitSingleEvaTempMsgLocQtyComRespDto = null;
    ImplementInitSingleEvaTempMsgLocQtyComReqDto implementInitSingleEvaTempMsgLocQtyComReqDto=new ImplementInitSingleEvaTempMsgLocQtyComReqDto();
  implementInitSingleEvaTempMsgLocQtyComReqDto.setReportTaskEvaRoom("MY_REPORT_TASK");//sourceId:1508306_1_60271
if(circulationCollectionsRes!=null){
      implementInitSingleEvaTempMsgLocQtyComReqDto.setOriginalRoleMemberId(circulationCollectionsRes.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508307_1_60271
implementInitSingleEvaTempMsgLocQtyComReqDto.setUserId(circulationCollectionsRes.getUserId());//SimpleFieldAssign//sourceId:1508308_1_60271
    }
if(reqDto!=null){
      implementInitSingleEvaTempMsgLocQtyComReqDto.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508309_1_60271
implementInitSingleEvaTempMsgLocQtyComReqDto.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508310_1_60271
    }
  
    /*D2-初始化单个评价模板位置消息数量（我汇报的）[8343]   */
    Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getReportTaskEvaRoom(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-汇报任务评价房间不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getOriginalRoleMemberId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-身份人员ID不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getUserId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-账号不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getEvaluationTemplateId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-冗余评价模板ID不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto.getSpaceId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我汇报的）-创建于空间ID不能为空",false);
      implementInitSingleEvaTempMsgLocQtyComRespDto = fwCompMessageClient.implementInitSingleEvaTempMsgLocQtyCom(implementInitSingleEvaTempMsgLocQtyComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      

//ModelCode: circulationEnd
        }
      
      }
//virtualUsage 3-6-02查评价模板下所有小圈子的主管列表  60270
      List<OmsVirtualOrgMember> listOmsVirtualOrgMember_2 =new ArrayList<>();
    QueryMsgSendVirtualOrgMemberListReq queryMsgSendVirtualOrgMemberListReq_1=new QueryMsgSendVirtualOrgMemberListReq();
  queryMsgSendVirtualOrgMemberListReq_1.setUseScene("TARGET_PLAN_SCENE");//sourceId:1509550_1_60270
queryMsgSendVirtualOrgMemberListReq_1.setRoleCode("DIRECTOR");//CUSTOM_CONVENTION//sourceId:1509560_1_60270
queryMsgSendVirtualOrgMemberListReq_1.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1509551_1_60270
if(reqDto!=null){
      queryMsgSendVirtualOrgMemberListReq_1.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1509556_1_60270
queryMsgSendVirtualOrgMemberListReq_1.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1509552_1_60270
    }
  
    /*3-6-02查评价模板下所有小圈子的主管列表[8224]   */
    Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getUseScene(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-虚拟组织使用场景不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getRoleCode(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-角色标识不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getSubjectLifeCycle(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-主体生命周期不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getEvaluationTemplateId(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-归属对象ID不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_1.getSpaceId(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的主管列表-创建于空间ID不能为空",false);
      listOmsVirtualOrgMember_2 = mOmsVirtualOrgMemberService.queryMsgSendVirtualOrgMemberList(queryMsgSendVirtualOrgMemberListReq_1)/*vcase invoke 本地 method 方法调用;*/;
      
      
      
//virtualUsage D2执行多字段数据集记录去重(公共)  60272
      ImplementManyFieldsDataSetDuplicateRemovalComRespDto implementManyFieldsDataSetDuplicateRemovalComRespDto_2 = null;
    if(listOmsVirtualOrgMember_2 !=null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember_2)&& listOmsVirtualOrgMember_2.size()>0 ){
          ImplementManyFieldsDataSetDuplicateRemovalComReqDto implementManyFieldsDataSetDuplicateRemovalComReqDto_1=new ImplementManyFieldsDataSetDuplicateRemovalComReqDto();
  if(listOmsVirtualOrgMember_2!= null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember_2)&&  listOmsVirtualOrgMember_2 !=null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember_2)){
      implementManyFieldsDataSetDuplicateRemovalComReqDto_1.setDataSetDuplicateRemovalList(//objList-to-objLists
        listOmsVirtualOrgMember_2.stream().map(item -> {
      DataSetDuplicateRemovalDto elm = new DataSetDuplicateRemovalDto();
      elm.setCommPrimaryKey(item.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:296500_2_60272
elm.setCustomField1(item.getUserId());//SimpleFieldAssign//sourceId:296501_2_60272
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1507956_1_60272
    }
  
    /*D2执行多字段数据集记录去重(公共)[7323]   */
    
      implementManyFieldsDataSetDuplicateRemovalComRespDto_2 = fwCompInterfaceModeClient.implementManyFieldsDataSetDuplicateRemovalCom(implementManyFieldsDataSetDuplicateRemovalComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
if((implementManyFieldsDataSetDuplicateRemovalComRespDto_2!= null&&  implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList() !=null && implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList().size()>0)) {
        //if(D2将所有小圈子的主管按身份人员去重(公共).数据集记录去重列表数据集条数 大于 0)  60273
        
//ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes_2 = null;
    if(implementManyFieldsDataSetDuplicateRemovalComRespDto_2 !=null){
          ImplementFourthReceivingFieldReqDto receptionServiceReq_1=new ImplementFourthReceivingFieldReqDto();
  if(implementManyFieldsDataSetDuplicateRemovalComRespDto_2!= null&&  implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList() !=null&& !CollectionUtil.isEmpty(implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList())){
      receptionServiceReq_1.setVirtualOrgMemberList(//objList-to-objLists
        implementManyFieldsDataSetDuplicateRemovalComRespDto_2.getDataSetDuplicateRemovalList().stream().map(item -> {
      VirtualOrgMemberDto elm = new VirtualOrgMemberDto();
      if(item!=null){
      elm.setOriginalRoleMemberId(item.getCommPrimaryKey());//SimpleFieldAssign//sourceId:296527_2_60274
elm.setUserId(item.getCustomField1());//SimpleFieldAssign//sourceId:296528_2_60274
    }
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508297_1_60274
    }

    /*M3用于接收数据集入参[8259]  用于特殊方法接收上游入参。 */

      receptionServiceRes_2 = nbCommunication.implementFourthReceivingField(receptionServiceReq_1);



           }
//ModelCode: circulationCollections
        for (VirtualOrgMemberDto circulationCollectionsRes_2: receptionServiceRes_2.getVirtualOrgMemberList()){

ImplementInitSingleEvaTempMsgLocQtyComRespDto implementInitSingleEvaTempMsgLocQtyComRespDto_1 = null;
    ImplementInitSingleEvaTempMsgLocQtyComReqDto implementInitSingleEvaTempMsgLocQtyComReqDto_1=new ImplementInitSingleEvaTempMsgLocQtyComReqDto();
  implementInitSingleEvaTempMsgLocQtyComReqDto_1.setReportTaskEvaRoom("TASK_REPORT_TO_ME");//sourceId:1508311_1_60276
if(circulationCollectionsRes_2!=null){
      implementInitSingleEvaTempMsgLocQtyComReqDto_1.setOriginalRoleMemberId(circulationCollectionsRes_2.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508312_1_60276
implementInitSingleEvaTempMsgLocQtyComReqDto_1.setUserId(circulationCollectionsRes_2.getUserId());//SimpleFieldAssign//sourceId:1508313_1_60276
    }
if(reqDto!=null){
      implementInitSingleEvaTempMsgLocQtyComReqDto_1.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508314_1_60276
implementInitSingleEvaTempMsgLocQtyComReqDto_1.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508315_1_60276
    }

    /*D2-初始化单个评价模板位置消息数量（汇报给我的）[8343]   */
    Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getReportTaskEvaRoom(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-汇报任务评价房间不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getOriginalRoleMemberId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-身份人员ID不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getUserId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-账号不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getEvaluationTemplateId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-冗余评价模板ID不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_1.getSpaceId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（汇报给我的）-创建于空间ID不能为空",false);
      implementInitSingleEvaTempMsgLocQtyComRespDto_1 = fwCompMessageClient.implementInitSingleEvaTempMsgLocQtyCom(implementInitSingleEvaTempMsgLocQtyComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;



//ModelCode: circulationEnd
        }

      }
//virtualUsage 3-6-02查评价模板下所有小圈子的相关人列表  60241
      List<OmsVirtualOrgMember> listOmsVirtualOrgMember_4 =new ArrayList<>();
    QueryMsgSendVirtualOrgMemberListReq queryMsgSendVirtualOrgMemberListReq_2=new QueryMsgSendVirtualOrgMemberListReq();
  queryMsgSendVirtualOrgMemberListReq_2.setUseScene("TARGET_PLAN_SCENE");//sourceId:1508322_1_60241
queryMsgSendVirtualOrgMemberListReq_2.setIsUpperLowerLevels("FALSE");//sourceId:1508327_1_60241
queryMsgSendVirtualOrgMemberListReq_2.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1508323_1_60241
if(reqDto!=null){
      queryMsgSendVirtualOrgMemberListReq_2.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508328_1_60241
queryMsgSendVirtualOrgMemberListReq_2.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508324_1_60241
    }

    /*3-6-02查评价模板下所有小圈子的相关人列表[8224]   */
    Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getUseScene(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-虚拟组织使用场景不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getIsUpperLowerLevels(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-是否上下级关系不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getSubjectLifeCycle(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-主体生命周期不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getEvaluationTemplateId(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-归属对象ID不能为空",false);
Assert.isNull(queryMsgSendVirtualOrgMemberListReq_2.getSpaceId(),"D3-执行初始化单个评价模板位置消息数量(公共)-3-6-02查评价模板下所有小圈子的相关人列表-创建于空间ID不能为空",false);
      listOmsVirtualOrgMember_4 = mOmsVirtualOrgMemberService.queryMsgSendVirtualOrgMemberList(queryMsgSendVirtualOrgMemberListReq_2)/*vcase invoke 本地 method 方法调用;*/;



//virtualUsage D2执行多字段数据集记录去重(公共)  60242
      ImplementManyFieldsDataSetDuplicateRemovalComRespDto implementManyFieldsDataSetDuplicateRemovalComRespDto_3 = null;
    if(listOmsVirtualOrgMember_4 !=null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember_4)&& listOmsVirtualOrgMember_4.size()>0 ){
          ImplementManyFieldsDataSetDuplicateRemovalComReqDto implementManyFieldsDataSetDuplicateRemovalComReqDto_2=new ImplementManyFieldsDataSetDuplicateRemovalComReqDto();
  if(listOmsVirtualOrgMember_4!= null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember_4)&&  listOmsVirtualOrgMember_4 !=null&& !CollectionUtil.isEmpty(listOmsVirtualOrgMember_4)){
      implementManyFieldsDataSetDuplicateRemovalComReqDto_2.setDataSetDuplicateRemovalList(//objList-to-objLists
        listOmsVirtualOrgMember_4.stream().map(item -> {
      DataSetDuplicateRemovalDto elm = new DataSetDuplicateRemovalDto();
      elm.setCommPrimaryKey(item.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:296500_2_60242
elm.setCustomField1(item.getUserId());//SimpleFieldAssign//sourceId:296501_2_60242
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1507956_1_60242
    }

    /*D2执行多字段数据集记录去重(公共)[7323]   */

      implementManyFieldsDataSetDuplicateRemovalComRespDto_3 = fwCompInterfaceModeClient.implementManyFieldsDataSetDuplicateRemovalCom(implementManyFieldsDataSetDuplicateRemovalComReqDto_2).getData()/*vcase invoke 跨dubbo调用;*/;



           }
if((implementManyFieldsDataSetDuplicateRemovalComRespDto_3!= null&&  implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList() !=null && implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList().size()>0)) {
        //if(D2将所有小圈子的相关人按身份人员去重(公共).数据集记录去重列表数据集条数 大于 0)  60243

//ModelCode: receptionService
        ImplementFourthReceivingFieldRespDto receptionServiceRes_3 = null;
    if(implementManyFieldsDataSetDuplicateRemovalComRespDto_3 !=null){
          ImplementFourthReceivingFieldReqDto receptionServiceReq_2=new ImplementFourthReceivingFieldReqDto();
  if(implementManyFieldsDataSetDuplicateRemovalComRespDto_3!= null&&  implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList() !=null&& !CollectionUtil.isEmpty(implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList())){
      receptionServiceReq_2.setVirtualOrgMemberList(//objList-to-objLists
        implementManyFieldsDataSetDuplicateRemovalComRespDto_3.getDataSetDuplicateRemovalList().stream().map(item -> {
      VirtualOrgMemberDto elm = new VirtualOrgMemberDto();
if(item!=null){
      elm.setOriginalRoleMemberId(item.getCommPrimaryKey());//SimpleFieldAssign//sourceId:296527_2_60244
elm.setUserId(item.getCustomField1());//SimpleFieldAssign//sourceId:296528_2_60244
    }
        return elm;
      }).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508297_1_60244
    }
  
    /*M3用于接收数据集入参[8259]  用于特殊方法接收上游入参。 */
    
      receptionServiceRes_3 = nbCommunication.implementFourthReceivingField(receptionServiceReq_2);
      
      
      
           }
//ModelCode: circulationCollections
        for (VirtualOrgMemberDto circulationCollectionsRes_3: receptionServiceRes_3.getVirtualOrgMemberList()){
      
ImplementInitSingleEvaTempMsgLocQtyComRespDto implementInitSingleEvaTempMsgLocQtyComRespDto_2 = null;
    ImplementInitSingleEvaTempMsgLocQtyComReqDto implementInitSingleEvaTempMsgLocQtyComReqDto_2=new ImplementInitSingleEvaTempMsgLocQtyComReqDto();
  implementInitSingleEvaTempMsgLocQtyComReqDto_2.setReportTaskEvaRoom("TASK_RELATED_TO_ME");//sourceId:1508316_1_60247
if(circulationCollectionsRes_3!=null){
      implementInitSingleEvaTempMsgLocQtyComReqDto_2.setOriginalRoleMemberId(circulationCollectionsRes_3.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508317_1_60247
implementInitSingleEvaTempMsgLocQtyComReqDto_2.setUserId(circulationCollectionsRes_3.getUserId());//SimpleFieldAssign//sourceId:1508318_1_60247
    }
if(reqDto!=null){
      implementInitSingleEvaTempMsgLocQtyComReqDto_2.setEvaluationTemplateId(reqDto.getEvaluationTemplateId());//SimpleFieldAssign//sourceId:1508319_1_60247
implementInitSingleEvaTempMsgLocQtyComReqDto_2.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1508320_1_60247
    }
  
    /*D2-初始化单个评价模板位置消息数量（我相关的）[8343]   */
    Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getReportTaskEvaRoom(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-汇报任务评价房间不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getOriginalRoleMemberId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-身份人员ID不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getUserId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-账号不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getEvaluationTemplateId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-冗余评价模板ID不能为空",false);
Assert.isNull(implementInitSingleEvaTempMsgLocQtyComReqDto_2.getSpaceId(),"D3-执行初始化单个评价模板位置消息数量(公共)-D2-初始化单个评价模板位置消息数量（我相关的）-创建于空间ID不能为空",false);
      implementInitSingleEvaTempMsgLocQtyComRespDto_2 = fwCompMessageClient.implementInitSingleEvaTempMsgLocQtyCom(implementInitSingleEvaTempMsgLocQtyComReqDto_2).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
//ModelCode: circulationEnd
        }
      
      }
ImplementSingleEvaTempMsgLocQtyComRespDto retData = new ImplementSingleEvaTempMsgLocQtyComRespDto();
  
  

  
  
return retData;
  }
/**
   * D3执行分享到部门大家想法(公共)[8358]
   * gen by moon at 2/23/2024, 2:19:40 AM
   */
  @Trace(operationName = "D3执行分享到部门大家想法(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementShareEveryoneIdeasDeptComRespDto implementShareEveryoneIdeasDeptCom(ImplementShareEveryoneIdeasDeptComReqDto reqDto){
    
      
      //virtualUsage D2-查询当前分享的消息（想法或笔记）  60268
      QueryMessageDetailComRespDto queryMessageDetailComRespDto = null;
    QueryMessageDetailComReqDto queryMessageDetailComReqDto=new QueryMessageDetailComReqDto();
  queryMessageDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1509524_1_60268
if(reqDto!=null){
      queryMessageDetailComReqDto.setMessageId(reqDto.getMessageId());//SimpleFieldAssign//sourceId:1509523_1_60268
    }
  
    /*D2-查询当前分享的消息（想法或笔记）[7526]   */
    Assert.isNull(queryMessageDetailComReqDto.getMessageId(),"D3执行分享到部门大家想法(公共)-D2-查询当前分享的消息（想法或笔记）-消息ID不能为空",false);
Assert.isNull(queryMessageDetailComReqDto.getSpaceId(),"D3执行分享到部门大家想法(公共)-D2-查询当前分享的消息（想法或笔记）-创建于空间ID不能为空",false);
      queryMessageDetailComRespDto = fwCompMessageClient.queryMessageDetailCom(queryMessageDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      Assert.isTrue(queryMessageDetailComRespDto== null||  queryMessageDetailComRespDto.getMessageId() ==null,"找不到数据，系统异常",false);
      
      
//virtualUsage D1-3查发送人头像、姓名、身份人员ID等（分享人）  60259
      QueryInductionRecordInfoDetailComRespDto queryInductionRecordInfoDetailComRespDto = null;
    QueryInductionRecordInfoDetailComReqDto queryInductionRecordInfoDetailComReqDto=new QueryInductionRecordInfoDetailComReqDto();
  queryInductionRecordInfoDetailComReqDto.setInductionRecordId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecInductionRecordId());//CURRENT_INDUCTIONID//sourceId:1508253_1_60259
queryInductionRecordInfoDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508261_1_60259
  
    /*D1-3查发送人头像、姓名、身份人员ID等（分享人）[715]   */
    Assert.isNull(queryInductionRecordInfoDetailComReqDto.getInductionRecordId(),"D3执行分享到部门大家想法(公共)-D1-3查发送人头像、姓名、身份人员ID等（分享人）-就职记录ID不能为空",false);
Assert.isNull(queryInductionRecordInfoDetailComReqDto.getSpaceId(),"D3执行分享到部门大家想法(公共)-D1-3查发送人头像、姓名、身份人员ID等（分享人）-创建于空间ID不能为空",false);
      queryInductionRecordInfoDetailComRespDto = fwBaseInductionRecordClient.queryInductionRecordInfoDetailCom(queryInductionRecordInfoDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      Assert.isTrue(queryInductionRecordInfoDetailComRespDto== null||  queryInductionRecordInfoDetailComRespDto.getInductionRecordId() ==null,"找不到数据，系统异常",false);
      
      
//virtualUsage D2生成“谁谁谁*邀请多人进入小岛  60260
      GenerateSemanticInstanceStoryComRespDto generateSemanticInstanceStoryComRespDto = null;
    if(queryInductionRecordInfoDetailComRespDto !=null){
          GenerateSemanticInstanceStoryComReqDto generateSemanticInstanceStoryComReqDto=new GenerateSemanticInstanceStoryComReqDto();
  generateSemanticInstanceStoryComReqDto.setTemplateSemanticEngineCode("CREATE_MULT_GROUP_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1508271_1_60260
generateSemanticInstanceStoryComReqDto.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1508265_1_60260
if(queryInductionRecordInfoDetailComRespDto!=null){
      generateSemanticInstanceStoryComReqDto.setFirstFieldValue(queryInductionRecordInfoDetailComRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1508266_1_60260
    }
  
    /*D2生成“谁谁谁*邀请多人进入小岛[8234]   */
    Assert.isNull(generateSemanticInstanceStoryComReqDto.getTemplateSemanticEngineCode(),"D3执行分享到部门大家想法(公共)-D2生成“谁谁谁*邀请多人进入小岛-模板引擎标识不能为空",false);
Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldName(),"D3执行分享到部门大家想法(公共)-D2生成“谁谁谁*邀请多人进入小岛-第一个字段字段名不能为空",false);
Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldValue(),"D3执行分享到部门大家想法(公共)-D2生成“谁谁谁*邀请多人进入小岛-第一个字段字段值不能为空",false);
      generateSemanticInstanceStoryComRespDto = fwCompTemplateEngineClient.generateSemanticInstanceStoryCom(generateSemanticInstanceStoryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
//virtualUsage D2查询通道详情(公共)  60269
      QueryChannelDetailComRespDto queryChannelDetailComRespDto = null;
    QueryChannelDetailComReqDto queryChannelDetailComReqDto=new QueryChannelDetailComReqDto();
  queryChannelDetailComReqDto.setChannelTypeCode("DEPT_IDEA_GROUP");//sourceId:1509468_1_60269
queryChannelDetailComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1509470_1_60269
if(reqDto!=null){
      queryChannelDetailComReqDto.setEntityId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1509469_1_60269
    }
  
    /*D2查询通道详情(公共)[7101]   */
    Assert.isNull(queryChannelDetailComReqDto.getChannelTypeCode(),"D3执行分享到部门大家想法(公共)-D2查询通道详情(公共)-通道类型编码不能为空",false);
Assert.isNull(queryChannelDetailComReqDto.getEntityId(),"D3执行分享到部门大家想法(公共)-D2查询通道详情(公共)-归属主体内容ID不能为空",false);
Assert.isNull(queryChannelDetailComReqDto.getSpaceId(),"D3执行分享到部门大家想法(公共)-D2查询通道详情(公共)-创建于空间ID不能为空",false);
      queryChannelDetailComRespDto = fwCompMessageClient.queryChannelDetailCom(queryChannelDetailComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
if((queryChannelDetailComRespDto != null  && queryChannelDetailComRespDto.getMessageChannelId() ==null)) {
        //if(D2查询通道详情(公共).通道ID 值等于空 )  60254
        
QueryDeptDetailComBorderRespDto queryDeptDetailComBorderRespDto = null;
    QueryDeptDetailComBorderReqDto queryDeptDetailComBorderReqDto=new QueryDeptDetailComBorderReqDto();
  queryDeptDetailComBorderReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1558527_1_61650
if(reqDto!=null){
      queryDeptDetailComBorderReqDto.setDeptId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1558513_1_61650
    }

    /*D1-3查询部门详情(公共)(边界)[2691]   */
    Assert.isNull(queryDeptDetailComBorderReqDto.getDeptId(),"D3执行分享到部门大家想法(公共)-D1-3查询部门详情(公共)(边界)-部门ID不能为空",false);
Assert.isNull(queryDeptDetailComBorderReqDto.getSubjectLifeCycle(),"D3执行分享到部门大家想法(公共)-D1-3查询部门详情(公共)(边界)-主体生命周期不能为空",false);
      queryDeptDetailComBorderRespDto = fwBaseOrgClient.queryDeptDetailComBorder(queryDeptDetailComBorderReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      Assert.isTrue(queryDeptDetailComBorderRespDto== null||  queryDeptDetailComBorderRespDto.getDeptCode() ==null,"找不到数据，系统异常",false);


QuerySubordinateDeptTreeListComBorderRespDto querySubordinateDeptTreeListComBorderRespDto = null;
    if(queryDeptDetailComBorderRespDto !=null){
          QuerySubordinateDeptTreeListComBorderReqDto querySubordinateDeptTreeListComBorderReqDto=new QuerySubordinateDeptTreeListComBorderReqDto();
  querySubordinateDeptTreeListComBorderReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1558499_1_61641
if(queryDeptDetailComBorderRespDto!=null){
      querySubordinateDeptTreeListComBorderReqDto.setDeptCode(queryDeptDetailComBorderRespDto.getDeptCode());//SimpleFieldAssign//sourceId:1558497_1_61641
    }

    /*D1-3查询下级部门树状结构(公共)(边界)[1845]   */
    Assert.isNull(querySubordinateDeptTreeListComBorderReqDto.getDeptCode(),"D3执行分享到部门大家想法(公共)-D1-3查询下级部门树状结构(公共)(边界)-部门标识不能为空",false);
Assert.isNull(querySubordinateDeptTreeListComBorderReqDto.getSubjectLifeCycle(),"D3执行分享到部门大家想法(公共)-D1-3查询下级部门树状结构(公共)(边界)-主体生命周期不能为空",false);
      querySubordinateDeptTreeListComBorderRespDto = fwBaseOrgClient.querySubordinateDeptTreeListComBorder(querySubordinateDeptTreeListComBorderReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      Assert.isTrue(querySubordinateDeptTreeListComBorderRespDto== null||  querySubordinateDeptTreeListComBorderRespDto.getDeptList() ==null|| CollectionUtil.isEmpty(querySubordinateDeptTreeListComBorderRespDto.getDeptList())|| querySubordinateDeptTreeListComBorderRespDto.getDeptList().size()==0 ,"找不到数据，系统异常",false);


           }
ImplementDeptInductionComRespDto implementDeptInductionComRespDto = null;
    if(querySubordinateDeptTreeListComBorderRespDto !=null){
          ImplementDeptInductionComReqDto implementDeptInductionComReqDto=new ImplementDeptInductionComReqDto();
  implementDeptInductionComReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1558505_1_61642
implementDeptInductionComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1558506_1_61642
if(querySubordinateDeptTreeListComBorderRespDto!= null&&  querySubordinateDeptTreeListComBorderRespDto.getDeptList() !=null&& !CollectionUtil.isEmpty(querySubordinateDeptTreeListComBorderRespDto.getDeptList())){
      implementDeptInductionComReqDto.setDeptMatchInductionList(querySubordinateDeptTreeListComBorderRespDto.getDeptList().stream().map(item->item.getDeptId())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1558504_1_61642
    }
  
    /*D1执行批量部门查就职记录(公共)[8523]   */
    Assert.isNull(implementDeptInductionComReqDto.getSubjectLifeCycle(),"D3执行分享到部门大家想法(公共)-D1执行批量部门查就职记录(公共)-主体生命周期不能为空",false);
Assert.isNull(implementDeptInductionComReqDto.getSpaceId(),"D3执行分享到部门大家想法(公共)-D1执行批量部门查就职记录(公共)-创建于空间ID不能为空",false);
      implementDeptInductionComRespDto = fwBaseInductionRecordClient.implementDeptInductionCom(implementDeptInductionComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      Assert.isTrue(implementDeptInductionComRespDto== null||  implementDeptInductionComRespDto.getDeptMatchInductionList() ==null|| CollectionUtil.isEmpty(implementDeptInductionComRespDto.getDeptMatchInductionList())|| implementDeptInductionComRespDto.getDeptMatchInductionList().size()==0 ,"找不到数据，系统异常",false);
      

           }
ObtainOrgMemberMsgReceiveInfoComRespDto obtainOrgMemberMsgReceiveInfoComRespDto = null;
    if(implementDeptInductionComRespDto !=null){
          ObtainOrgMemberMsgReceiveInfoComReqDto obtainOrgMemberMsgReceiveInfoComReqDto=new ObtainOrgMemberMsgReceiveInfoComReqDto();
  obtainOrgMemberMsgReceiveInfoComReqDto.setSenderOriginalRoleMemberId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecOriginalRoleMemberId());//CURRENT_ORIGINAL_ROLE_MEMBERID//sourceId:1508968_1_60257
if(implementDeptInductionComRespDto!= null&&  implementDeptInductionComRespDto.getDeptMatchInductionList() !=null&& !CollectionUtil.isEmpty(implementDeptInductionComRespDto.getDeptMatchInductionList())){
      obtainOrgMemberMsgReceiveInfoComReqDto.setBeginMemberList(implementDeptInductionComRespDto.getDeptMatchInductionList().stream().map(item->item.getOriginalRoleMemberId())
        .collect(Collectors.toList()));/*list-to-strings*///sourceId:1508967_1_60257
    }
  
    /*D1获取组织成员消息接收人信息(公共)[7972]   */
    Assert.isNull(obtainOrgMemberMsgReceiveInfoComReqDto.getSenderOriginalRoleMemberId(),"D3执行分享到部门大家想法(公共)-D1获取组织成员消息接收人信息(公共)-发送方身份人员ID不能为空",false);
      obtainOrgMemberMsgReceiveInfoComRespDto = fwBaseMessageClient.obtainOrgMemberMsgReceiveInfoCom(obtainOrgMemberMsgReceiveInfoComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
ImplementSendChannelMessageComRespDto implementSendChannelMessageComRespDto = null;
    if(obtainOrgMemberMsgReceiveInfoComRespDto !=null&&queryInductionRecordInfoDetailComRespDto !=null&&queryMessageDetailComRespDto !=null&&generateSemanticInstanceStoryComRespDto !=null){
          ImplementSendChannelMessageComReqDto implementSendChannelMessageComReqDto=new ImplementSendChannelMessageComReqDto();
  implementSendChannelMessageComReqDto.setBorcScene("TOB_SCENE");//sourceId:1508224_1_60261
implementSendChannelMessageComReqDto.setPlatformReplace("FALSE");//sourceId:1508225_1_60261
implementSendChannelMessageComReqDto.setMessageLocationTypeCode("RECORD_IDEAS");//CUSTOM_CONVENTION//sourceId:1508223_1_60261
implementSendChannelMessageComReqDto.setChannelTypeCode("DEPT_IDEA_GROUP");//sourceId:1508226_1_60261
implementSendChannelMessageComReqDto.setMsgChannelClassCode("IDEA");//sourceId:1508252_1_60261
implementSendChannelMessageComReqDto.setNewTableTypeCode("OMS_ORG_DEPT");//sourceId:1508211_1_60261
implementSendChannelMessageComReqDto.setGreetingMessageTemplateCode("TWO_PEOPLE_CHAT_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1509547_1_60261
implementSendChannelMessageComReqDto.setIsHandle("FALSE");//sourceId:1508237_1_60261
implementSendChannelMessageComReqDto.setHandleType("NEED_HANDLING");//sourceId:1508249_1_60261
implementSendChannelMessageComReqDto.setMessageImportantLevel(Long.valueOf(1));//CUSTOM_CONVENTION//sourceId:1508227_1_60261
implementSendChannelMessageComReqDto.setMessageRole("user");//sourceId:1508216_1_60261
implementSendChannelMessageComReqDto.setIsAssistant("FALSE");//sourceId:1508219_1_60261
implementSendChannelMessageComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508231_1_60261
implementSendChannelMessageComReqDto.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1508232_1_60261
if(obtainOrgMemberMsgReceiveInfoComRespDto!= null&&  obtainOrgMemberMsgReceiveInfoComRespDto.getMemberMsgReceiveList() !=null&& !CollectionUtil.isEmpty(obtainOrgMemberMsgReceiveInfoComRespDto.getMemberMsgReceiveList())){
      implementSendChannelMessageComReqDto.setMemberChannelList(obtainOrgMemberMsgReceiveInfoComRespDto.getMemberMsgReceiveList().stream().map(item -> BeanUtil.toBean(item, com.wicket.okrcomponent.integration.dto.MemberChannelDto.class)).collect(Collectors.toList()));//objList-to-objLists//sourceId:1508222_1_60261
    }
if(reqDto!=null){
      implementSendChannelMessageComReqDto.setChannelName(reqDto.getChannelName());//SimpleFieldAssign//sourceId:1508209_1_60261
implementSendChannelMessageComReqDto.setNewEntityId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1508212_1_60261
    }
if(queryInductionRecordInfoDetailComRespDto!=null){
      implementSendChannelMessageComReqDto.setChannelLogo(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508210_1_60261
implementSendChannelMessageComReqDto.setNameOfSender(queryInductionRecordInfoDetailComRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1508215_1_60261
implementSendChannelMessageComReqDto.setSenderProfilePictureAddress(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508214_1_60261
implementSendChannelMessageComReqDto.setSenderDeptId(queryInductionRecordInfoDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508246_1_60261
implementSendChannelMessageComReqDto.setSenderInductionRecordId(queryInductionRecordInfoDetailComRespDto.getInductionRecordId());//SimpleFieldAssign//sourceId:1508247_1_60261
implementSendChannelMessageComReqDto.setSenderOriginalRoleMemberId(queryInductionRecordInfoDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508217_1_60261
implementSendChannelMessageComReqDto.setSenderUserId(queryInductionRecordInfoDetailComRespDto.getUserId());//SimpleFieldAssign//sourceId:1508218_1_60261
    }
if(queryMessageDetailComRespDto!=null){
      implementSendChannelMessageComReqDto.setTableTypeCode(queryMessageDetailComRespDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1508235_1_60261
implementSendChannelMessageComReqDto.setEntityId(queryMessageDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508236_1_60261
implementSendChannelMessageComReqDto.setCooperateContentTypeCode(queryMessageDetailComRespDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1508241_1_60261
implementSendChannelMessageComReqDto.setCooperateContentId(queryMessageDetailComRespDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1508242_1_60261
implementSendChannelMessageComReqDto.setSurfaceContName(queryMessageDetailComRespDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1508243_1_60261
implementSendChannelMessageComReqDto.setMediaType(queryMessageDetailComRespDto.getMediaType());//SimpleFieldAssign//sourceId:1508239_1_60261
implementSendChannelMessageComReqDto.setMediaAddress(queryMessageDetailComRespDto.getMediaAddress());//SimpleFieldAssign//sourceId:1508240_1_60261
implementSendChannelMessageComReqDto.setThemeContentTypeCode(queryMessageDetailComRespDto.getThemeContentTypeCode());//SimpleFieldAssign//sourceId:1508229_1_60261
implementSendChannelMessageComReqDto.setThemeContentId(queryMessageDetailComRespDto.getThemeContentId());//SimpleFieldAssign//sourceId:1508230_1_60261
implementSendChannelMessageComReqDto.setMessageTemplateCode(queryMessageDetailComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1508228_1_60261
implementSendChannelMessageComReqDto.setMessageTitle(queryMessageDetailComRespDto.getMessageTitle());//SimpleFieldAssign//sourceId:1508220_1_60261
implementSendChannelMessageComReqDto.setMessageContent(queryMessageDetailComRespDto.getMessageContent());//SimpleFieldAssign//sourceId:1508213_1_60261
    }
if(generateSemanticInstanceStoryComRespDto!=null){
      implementSendChannelMessageComReqDto.setNewMessage(generateSemanticInstanceStoryComRespDto.getObjectName());//SimpleFieldAssign//sourceId:1508233_1_60261
    }
  
    /*D2执行发送通道N人消息(初次或后续生成临时冗余的消息)[7494]   */
    Assert.isNull(implementSendChannelMessageComReqDto.getBorcScene(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-toB或toC场景不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getPlatformReplace(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否平台代操作不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getMessageLocationTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息位置标识不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getChannelName(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道名称不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getChannelLogo(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道缩略图地址不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getChannelTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道类型编码不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getMsgChannelClassCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息使用通道类别不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getNewTableTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容类型编码不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getNewEntityId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getTableTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表类型编码不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getEntityId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表主键 ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getGreetingMessageTemplateCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-欢迎语消息模板标识不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getNewMessage(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-拉人进群欢迎消息文本不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getMessageTemplateCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息模板标识不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getMessageTitle(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息标题不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getMessageContent(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息内容不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getIsHandle(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否已处理不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getHandleType(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-处理类型不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getMessageImportantLevel(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getNameOfSender(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方姓名不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getSenderProfilePictureAddress(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方头像地址不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getMessageRole(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方角色不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getSenderDeptId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职部门ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getSenderInductionRecordId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职记录ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getSenderOriginalRoleMemberId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方身份人员ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getSenderUserId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方账号ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getIsAssistant(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方是否助手不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getSpaceId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于空间ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto.getAppId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于联盟应用ID不能为空",false);
      implementSendChannelMessageComRespDto = fwCompMessageClient.implementSendChannelMessageCom(implementSendChannelMessageComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
ImplementShareIdeasDeleteBackComRespDto implementShareIdeasDeleteBackComRespDto = null;
    if(implementSendChannelMessageComRespDto !=null&&queryMessageDetailComRespDto !=null){
          ImplementShareIdeasDeleteBackComReqDto implementShareIdeasDeleteBackComReqDto=new ImplementShareIdeasDeleteBackComReqDto();
  implementShareIdeasDeleteBackComReqDto.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508957_1_60262
if(implementSendChannelMessageComRespDto!=null){
      implementShareIdeasDeleteBackComReqDto.setMessageId(implementSendChannelMessageComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1508955_1_60262
    }
if(queryMessageDetailComRespDto!=null){
      implementShareIdeasDeleteBackComReqDto.setReceiveMessageId(queryMessageDetailComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1509762_1_60262
    }
  
    /*D2执行分享想法后回删(公共)[8360]   */
    Assert.isNull(implementShareIdeasDeleteBackComReqDto.getMessageId(),"D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-消息ID不能为空",false);
Assert.isNull(implementShareIdeasDeleteBackComReqDto.getReceiveMessageId(),"D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-接收的消息ID不能为空",false);
Assert.isNull(implementShareIdeasDeleteBackComReqDto.getSpaceId(),"D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-创建于空间ID不能为空",false);
      implementShareIdeasDeleteBackComRespDto = fwCompCommunicationClient.implementShareIdeasDeleteBackCom(implementShareIdeasDeleteBackComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
      }
else{
       //else  60255
      
ImplementSendChannelMessageComRespDto implementSendChannelMessageComRespDto_2 = null;
    if(queryInductionRecordInfoDetailComRespDto !=null&&queryMessageDetailComRespDto !=null&&generateSemanticInstanceStoryComRespDto !=null){
          ImplementSendChannelMessageComReqDto implementSendChannelMessageComReqDto_1=new ImplementSendChannelMessageComReqDto();
  implementSendChannelMessageComReqDto_1.setBorcScene("TOB_SCENE");//sourceId:1508224_1_60263
implementSendChannelMessageComReqDto_1.setPlatformReplace("FALSE");//sourceId:1508225_1_60263
implementSendChannelMessageComReqDto_1.setMessageLocationTypeCode("RECORD_IDEAS");//CUSTOM_CONVENTION//sourceId:1508223_1_60263
implementSendChannelMessageComReqDto_1.setChannelTypeCode("DEPT_IDEA_GROUP");//sourceId:1508226_1_60263
implementSendChannelMessageComReqDto_1.setMsgChannelClassCode("IDEA");//sourceId:1508252_1_60263
implementSendChannelMessageComReqDto_1.setNewTableTypeCode("OMS_ORG_DEPT");//sourceId:1508211_1_60263
implementSendChannelMessageComReqDto_1.setGreetingMessageTemplateCode("TWO_PEOPLE_CHAT_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1509547_1_60263
implementSendChannelMessageComReqDto_1.setIsHandle("FALSE");//sourceId:1508237_1_60263
implementSendChannelMessageComReqDto_1.setHandleType("NEED_HANDLING");//sourceId:1508249_1_60263
implementSendChannelMessageComReqDto_1.setMessageImportantLevel(Long.valueOf(1));//CUSTOM_CONVENTION//sourceId:1508227_1_60263
implementSendChannelMessageComReqDto_1.setMessageRole("user");//sourceId:1508216_1_60263
implementSendChannelMessageComReqDto_1.setIsAssistant("FALSE");//sourceId:1508219_1_60263
implementSendChannelMessageComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508231_1_60263
implementSendChannelMessageComReqDto_1.setAppId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecAppId());//CURRENT_APPID//sourceId:1508232_1_60263
if(reqDto!=null){
      implementSendChannelMessageComReqDto_1.setChannelName(reqDto.getChannelName());//SimpleFieldAssign//sourceId:1508209_1_60263
implementSendChannelMessageComReqDto_1.setNewEntityId(reqDto.getDeptId());//SimpleFieldAssign//sourceId:1508212_1_60263
    }
if(queryInductionRecordInfoDetailComRespDto!=null){
      implementSendChannelMessageComReqDto_1.setChannelLogo(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508210_1_60263
implementSendChannelMessageComReqDto_1.setNameOfSender(queryInductionRecordInfoDetailComRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1508215_1_60263
implementSendChannelMessageComReqDto_1.setSenderProfilePictureAddress(queryInductionRecordInfoDetailComRespDto.getUserFace());//SimpleFieldAssign//sourceId:1508214_1_60263
implementSendChannelMessageComReqDto_1.setSenderDeptId(queryInductionRecordInfoDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508246_1_60263
implementSendChannelMessageComReqDto_1.setSenderInductionRecordId(queryInductionRecordInfoDetailComRespDto.getInductionRecordId());//SimpleFieldAssign//sourceId:1508247_1_60263
implementSendChannelMessageComReqDto_1.setSenderOriginalRoleMemberId(queryInductionRecordInfoDetailComRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1508217_1_60263
implementSendChannelMessageComReqDto_1.setSenderUserId(queryInductionRecordInfoDetailComRespDto.getUserId());//SimpleFieldAssign//sourceId:1508218_1_60263
    }
if(queryMessageDetailComRespDto!=null){
      implementSendChannelMessageComReqDto_1.setTableTypeCode(queryMessageDetailComRespDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1508235_1_60263
implementSendChannelMessageComReqDto_1.setEntityId(queryMessageDetailComRespDto.getEntityId());//SimpleFieldAssign//sourceId:1508236_1_60263
implementSendChannelMessageComReqDto_1.setCooperateContentTypeCode(queryMessageDetailComRespDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1508241_1_60263
implementSendChannelMessageComReqDto_1.setCooperateContentId(queryMessageDetailComRespDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1508242_1_60263
implementSendChannelMessageComReqDto_1.setSurfaceContName(queryMessageDetailComRespDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1508243_1_60263
implementSendChannelMessageComReqDto_1.setMediaType(queryMessageDetailComRespDto.getMediaType());//SimpleFieldAssign//sourceId:1508239_1_60263
implementSendChannelMessageComReqDto_1.setMediaAddress(queryMessageDetailComRespDto.getMediaAddress());//SimpleFieldAssign//sourceId:1508240_1_60263
implementSendChannelMessageComReqDto_1.setThemeContentTypeCode(queryMessageDetailComRespDto.getThemeContentTypeCode());//SimpleFieldAssign//sourceId:1508229_1_60263
implementSendChannelMessageComReqDto_1.setThemeContentId(queryMessageDetailComRespDto.getThemeContentId());//SimpleFieldAssign//sourceId:1508230_1_60263
implementSendChannelMessageComReqDto_1.setMessageTemplateCode(queryMessageDetailComRespDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1508228_1_60263
implementSendChannelMessageComReqDto_1.setMessageTitle(queryMessageDetailComRespDto.getMessageTitle());//SimpleFieldAssign//sourceId:1508220_1_60263
implementSendChannelMessageComReqDto_1.setMessageContent(queryMessageDetailComRespDto.getMessageContent());//SimpleFieldAssign//sourceId:1508213_1_60263
    }
if(generateSemanticInstanceStoryComRespDto!=null){
      implementSendChannelMessageComReqDto_1.setNewMessage(generateSemanticInstanceStoryComRespDto.getObjectName());//SimpleFieldAssign//sourceId:1508233_1_60263
    }
  
    /*D2执行发送通道N人消息(初次或后续生成临时冗余的消息)[7494]   */
    Assert.isNull(implementSendChannelMessageComReqDto_1.getBorcScene(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-toB或toC场景不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getPlatformReplace(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否平台代操作不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageLocationTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息位置标识不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getChannelName(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道名称不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getChannelLogo(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道缩略图地址不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getChannelTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道类型编码不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getMsgChannelClassCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息使用通道类别不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getNewTableTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容类型编码不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getNewEntityId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-通道归属主体内容ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getTableTypeCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表类型编码不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getEntityId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息归属内容表主键 ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getGreetingMessageTemplateCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-欢迎语消息模板标识不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getNewMessage(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-拉人进群欢迎消息文本不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageTemplateCode(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息模板标识不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageTitle(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息标题不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageContent(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息内容不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getIsHandle(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-是否已处理不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getHandleType(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-处理类型不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageImportantLevel(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getNameOfSender(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方姓名不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderProfilePictureAddress(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方头像地址不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getMessageRole(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方角色不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderDeptId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职部门ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderInductionRecordId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方就职记录ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderOriginalRoleMemberId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方身份人员ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getSenderUserId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方账号ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getIsAssistant(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-发送方是否助手不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getSpaceId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于空间ID不能为空",false);
Assert.isNull(implementSendChannelMessageComReqDto_1.getAppId(),"D3执行分享到部门大家想法(公共)-D2执行发送通道N人消息(初次或后续生成临时冗余的消息)-创建于联盟应用ID不能为空",false);
      implementSendChannelMessageComRespDto_2 = fwCompMessageClient.implementSendChannelMessageCom(implementSendChannelMessageComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
ImplementShareIdeasDeleteBackComRespDto implementShareIdeasDeleteBackComRespDto_1 = null;
    if(implementSendChannelMessageComRespDto_2 !=null&&queryMessageDetailComRespDto !=null){
          ImplementShareIdeasDeleteBackComReqDto implementShareIdeasDeleteBackComReqDto_1=new ImplementShareIdeasDeleteBackComReqDto();
  implementShareIdeasDeleteBackComReqDto_1.setSpaceId(CommonFunctionHelper.getBaseInfoFromLocal().getSpecSpaceId());//CURRENT_SPACEID//sourceId:1508957_1_60264
if(implementSendChannelMessageComRespDto_2!=null){
      implementShareIdeasDeleteBackComReqDto_1.setMessageId(implementSendChannelMessageComRespDto_2.getMessageId());//SimpleFieldAssign//sourceId:1508955_1_60264
    }
if(queryMessageDetailComRespDto!=null){
      implementShareIdeasDeleteBackComReqDto_1.setReceiveMessageId(queryMessageDetailComRespDto.getMessageId());//SimpleFieldAssign//sourceId:1509762_1_60264
    }
  
    /*D2执行分享想法后回删(公共)[8360]   */
    Assert.isNull(implementShareIdeasDeleteBackComReqDto_1.getMessageId(),"D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-消息ID不能为空",false);
Assert.isNull(implementShareIdeasDeleteBackComReqDto_1.getReceiveMessageId(),"D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-接收的消息ID不能为空",false);
Assert.isNull(implementShareIdeasDeleteBackComReqDto_1.getSpaceId(),"D3执行分享到部门大家想法(公共)-D2执行分享想法后回删(公共)-创建于空间ID不能为空",false);
      implementShareIdeasDeleteBackComRespDto_1 = fwCompCommunicationClient.implementShareIdeasDeleteBackCom(implementShareIdeasDeleteBackComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;
      
      
      
           }
    }
ImplementShareEveryoneIdeasDeptComRespDto retData = new ImplementShareEveryoneIdeasDeptComRespDto();
  
  

  
  
return retData;
  }
/**
   * D3分析高中基层回退消息模板(公共)[8495]
   * gen by moon at 2/13/2024, 10:43:01 AM
   */
  @Trace(operationName = "D3分析高中基层回退消息模板(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public AnalysisTopMidBaiscBackMsgTempComRespDto analysisTopMidBaiscBackMsgTempCom(AnalysisTopMidBaiscBackMsgTempComReqDto reqDto){


      ObtainReceiveOutFieldRespDto receptionServiceRes_5 =null;
//virtualUsage M3约定高中基层回退操作消息模板标识  61341
      //ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes = null;
    ObtainReceiveOutFieldReqDto receptionServiceReq=new ObtainReceiveOutFieldReqDto();
  receptionServiceReq.setCustomField1("TOP_BACK_FIRST_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546099_1_61341
receptionServiceReq.setCustomField2("MID_BACK_FIRST_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546104_1_61341
receptionServiceReq.setCustomField3("MID_BACK_SEC_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546105_1_61341
receptionServiceReq.setCustomField4("BAISC_BACK_FIRST_STEP_MSG_TEMP");//CUSTOM_CONVENTION//sourceId:1546106_1_61341

    /*M3约定高中基层回退操作消息模板标识[4608]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq.getCustomField1(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段1不能为空",false);
Assert.isNull(receptionServiceReq.getCustomField2(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段2不能为空",false);
Assert.isNull(receptionServiceReq.getCustomField3(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段3不能为空",false);
Assert.isNull(receptionServiceReq.getCustomField4(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退操作消息模板标识-自定义字段4不能为空",false);
      receptionServiceRes = nbCommunication.obtainReceiveOutField(receptionServiceReq);



//virtualUsage M3约定高中基层回退消息标题语义引擎标识  61342
      //ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes_2 = null;
    ObtainReceiveOutFieldReqDto receptionServiceReq_1=new ObtainReceiveOutFieldReqDto();
  receptionServiceReq_1.setCustomField1("TOP_BACK_FIRST_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546411_1_61342
receptionServiceReq_1.setCustomField2("MID_BACK_FIRST_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546412_1_61342
receptionServiceReq_1.setCustomField3("MID_BACK_SEC_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546413_1_61342
receptionServiceReq_1.setCustomField4("BAISC_BACK_FIRST_STEP_MSG_TITLE");//CUSTOM_CONVENTION//sourceId:1546414_1_61342

    /*M3约定高中基层回退消息标题语义引擎标识[4608]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_1.getCustomField1(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段1不能为空",false);
Assert.isNull(receptionServiceReq_1.getCustomField2(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段2不能为空",false);
Assert.isNull(receptionServiceReq_1.getCustomField3(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段3不能为空",false);
Assert.isNull(receptionServiceReq_1.getCustomField4(),"D3分析高中基层回退消息模板(公共)-M3约定高中基层回退消息标题语义引擎标识-自定义字段4不能为空",false);
      receptionServiceRes_2 = nbCommunication.obtainReceiveOutField(receptionServiceReq_1);



if((reqDto!= null&&  reqDto.getSendMsgScene() !=null && reqDto.getSendMsgScene().equals("TOP_BACK_FIRST_STEP"))) {
        //if(D3分析高中基层回退消息模板(公共).发送消息场景 等于 高层返回第一步)  61337

//ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes_4 = null;
    ObtainReceiveOutFieldReqDto receptionServiceReq_2=new ObtainReceiveOutFieldReqDto();
  if(receptionServiceRes!=null){
      receptionServiceReq_2.setMessageTemplateCode(receptionServiceRes.getCustomField1());//SimpleFieldAssign//sourceId:1546089_1_61343
    }
if(receptionServiceRes_2!=null){
      receptionServiceReq_2.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField1());//SimpleFieldAssign//sourceId:1546090_1_61343
    }

    /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_2.getMessageTemplateCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_2.getMsgTitleTemplateSemanticEngineCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_4 = nbCommunication.obtainReceiveOutField(receptionServiceReq_2);


      receptionServiceRes_5 = receptionServiceRes_4;
      }
else if((reqDto!= null&&  reqDto.getSendMsgScene() !=null && reqDto.getSendMsgScene().equals("MID_BACK_FIRST_STEP"))){
       //elseif(D3分析高中基层回退消息模板(公共).发送消息场景 等于 中层返回第一步)  61338

//ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes_6 = null;
    ObtainReceiveOutFieldReqDto receptionServiceReq_3=new ObtainReceiveOutFieldReqDto();
  if(receptionServiceRes!=null){
      receptionServiceReq_3.setMessageTemplateCode(receptionServiceRes.getCustomField2());//SimpleFieldAssign//sourceId:1546089_1_61344
    }
if(receptionServiceRes_2!=null){
      receptionServiceReq_3.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField2());//SimpleFieldAssign//sourceId:1546090_1_61344
    }

    /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_3.getMessageTemplateCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_3.getMsgTitleTemplateSemanticEngineCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_6 = nbCommunication.obtainReceiveOutField(receptionServiceReq_3);


      receptionServiceRes_5 = receptionServiceRes_6;
    }
else if((reqDto!= null&&  reqDto.getSendMsgScene() !=null && reqDto.getSendMsgScene().equals("MID_BACK_SEC_STEP"))){
       //elseif(D3分析高中基层回退消息模板(公共).发送消息场景 等于 中层返回第二步)  61339

//ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes_7 = null;
    ObtainReceiveOutFieldReqDto receptionServiceReq_4=new ObtainReceiveOutFieldReqDto();
  if(receptionServiceRes!=null){
      receptionServiceReq_4.setMessageTemplateCode(receptionServiceRes.getCustomField3());//SimpleFieldAssign//sourceId:1546089_1_61345
    }
if(receptionServiceRes_2!=null){
      receptionServiceReq_4.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField3());//SimpleFieldAssign//sourceId:1546090_1_61345
    }

    /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_4.getMessageTemplateCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_4.getMsgTitleTemplateSemanticEngineCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_7 = nbCommunication.obtainReceiveOutField(receptionServiceReq_4);


      receptionServiceRes_5 = receptionServiceRes_7;
    }
else if((reqDto!= null&&  reqDto.getSendMsgScene() !=null && reqDto.getSendMsgScene().equals("BAISC_BACK_FIRST_STEP"))){
       //elseif(D3分析高中基层回退消息模板(公共).发送消息场景 等于 基层返回第一步)  61340

//ModelCode: receptionService
        ObtainReceiveOutFieldRespDto receptionServiceRes_8 = null;
    ObtainReceiveOutFieldReqDto receptionServiceReq_5=new ObtainReceiveOutFieldReqDto();
  if(receptionServiceRes!=null){
      receptionServiceReq_5.setMessageTemplateCode(receptionServiceRes.getCustomField4());//SimpleFieldAssign//sourceId:1546089_1_61346
    }
if(receptionServiceRes_2!=null){
      receptionServiceReq_5.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_2.getCustomField4());//SimpleFieldAssign//sourceId:1546090_1_61346
    }

    /*M3接收消息模板及消息标题引擎模板[4608]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq_5.getMessageTemplateCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq_5.getMsgTitleTemplateSemanticEngineCode(),"D3分析高中基层回退消息模板(公共)-M3接收消息模板及消息标题引擎模板-消息标题模板引擎标识不能为空",false);
      receptionServiceRes_8 = nbCommunication.obtainReceiveOutField(receptionServiceReq_5);


      receptionServiceRes_5 = receptionServiceRes_8;
    }
AnalysisTopMidBaiscBackMsgTempComRespDto retData = new AnalysisTopMidBaiscBackMsgTempComRespDto();
  if(receptionServiceRes_5!=null){
      retData.setMessageTemplateCode(receptionServiceRes_5.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1546097_1
retData.setMsgTitleTemplateSemanticEngineCode(receptionServiceRes_5.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1546098_1
    }




return retData;
  }
/**
   * D3执行预制内容发两人会话消息(公共)[8496]
   * gen by moon at 2/13/2024, 10:43:17 AM
   */
  @Trace(operationName = "D3执行预制内容发两人会话消息(公共)")
  @Tags({@Tag(key = "参数",value = "arg[0]"),
            @Tag(key = "返回值",value = "returnedObj")})
  @Transactional(rollbackFor=Exception.class)
  @Override
  public ImplementPrefabricateContentSendTwoPersonConvMsgComRespDto implementPrefabricateContentSendTwoPersonConvMsgCom(ImplementPrefabricateContentSendTwoPersonConvMsgComReqDto reqDto){


      //步骤0: M3-执行发送消息接收人范围专用接收字段（特殊方法） - implementSendMsgReceiverAcceptField
     //ModelCode: receptionService
        ImplementSendMsgReceiverAcceptFieldRespDto receptionServiceRes = null;
    ImplementSendMsgReceiverAcceptFieldReqDto receptionServiceReq=new ImplementSendMsgReceiverAcceptFieldReqDto();
  if(reqDto!=null){
      receptionServiceReq.setSendMsgScene(reqDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1546987_1
receptionServiceReq.setRoleCode(reqDto.getRoleCode());//SimpleFieldAssign//sourceId:1546988_1
receptionServiceReq.setUseScene(reqDto.getUseScene());//SimpleFieldAssign//sourceId:1546989_1
receptionServiceReq.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1546990_1
receptionServiceReq.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1546991_1
receptionServiceReq.setReceiveOriginalRoleMemberId(reqDto.getReceiveOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546992_1
receptionServiceReq.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546993_1
receptionServiceReq.setAppId(reqDto.getAppId());//SimpleFieldAssign//sourceId:1546994_1
receptionServiceReq.setNewTableTypeCode(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1547036_1
receptionServiceReq.setNewEntityId(reqDto.getNewEntityId());//SimpleFieldAssign//sourceId:1547037_1
receptionServiceReq.setSurfaceCode(reqDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1547038_1
receptionServiceReq.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1547039_1
receptionServiceReq.setPlatformReplace(reqDto.getPlatformReplace());//SimpleFieldAssign//sourceId:1547001_1
receptionServiceReq.setMessageTemplateCode(reqDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1547000_1
receptionServiceReq.setMsgTitleTemplateSemanticEngineCode(reqDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1547004_1
receptionServiceReq.setMessageImportantLevel(reqDto.getMessageImportantLevel());//SimpleFieldAssign//sourceId:1547003_1
receptionServiceReq.setMessageContent(reqDto.getMessageContent());//SimpleFieldAssign//sourceId:1547034_1
receptionServiceReq.setReferenceMessageId(reqDto.getReferenceMessageId());//SimpleFieldAssign//sourceId:1547002_1
receptionServiceReq.setCooperateContentTypeCode(reqDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1546995_1
receptionServiceReq.setCooperateContentId(reqDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1546996_1
receptionServiceReq.setSurfaceContName(reqDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1546997_1
receptionServiceReq.setMediaType(reqDto.getMediaType());//SimpleFieldAssign//sourceId:1546998_1
receptionServiceReq.setMediaAddress(reqDto.getMediaAddress());//SimpleFieldAssign//sourceId:1546999_1
receptionServiceReq.setIsHandle(reqDto.getIsHandle());//SimpleFieldAssign//sourceId:1547044_1
receptionServiceReq.setHandleType(reqDto.getHandleType());//SimpleFieldAssign//sourceId:1547045_1
receptionServiceReq.setComNumField(reqDto.getComNumField());//SimpleFieldAssign//sourceId:1547005_1
    }

    /*M3接收字段[8209]  用于特殊方法接收上游入参。 */
    Assert.isNull(receptionServiceReq.getSendMsgScene(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-发送消息场景不能为空",false);
Assert.isNull(receptionServiceReq.getReceiveOriginalRoleMemberId(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-接收方身份人员ID不能为空",false);
Assert.isNull(receptionServiceReq.getSpaceId(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-创建于空间ID不能为空",false);
Assert.isNull(receptionServiceReq.getAppId(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-创建于联盟应用ID不能为空",false);
Assert.isNull(receptionServiceReq.getNewTableTypeCode(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-通道归属主体内容类型编码不能为空",false);
Assert.isNull(receptionServiceReq.getNewEntityId(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-通道归属主体内容ID不能为空",false);
Assert.isNull(receptionServiceReq.getSurfaceCode(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-归属内容类型编码不能为空",false);
Assert.isNull(receptionServiceReq.getEntityId(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-归属内容ID不能为空",false);
Assert.isNull(receptionServiceReq.getPlatformReplace(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-是否平台代操作不能为空",false);
Assert.isNull(receptionServiceReq.getMessageTemplateCode(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-消息模板标识不能为空",false);
Assert.isNull(receptionServiceReq.getMsgTitleTemplateSemanticEngineCode(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-消息标题模板引擎标识不能为空",false);
Assert.isNull(receptionServiceReq.getMessageImportantLevel(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-消息重要紧急度层级不能为空",false);
Assert.isNull(receptionServiceReq.getMessageContent(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-消息内容不能为空",false);
Assert.isNull(receptionServiceReq.getHandleType(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-处理类型不能为空",false);
Assert.isNull(receptionServiceReq.getComNumField(),"D3执行预制内容发两人会话消息(公共)-M3接收字段-通用数值字段（整数型）不能为空",false);
      receptionServiceRes = nbCommunication.implementSendMsgReceiverAcceptField(receptionServiceReq);




//步骤1: D3分析批次内消息发送方身份信息(公共) - analysisBatchMessageSenderInfoCom
     AnalysisBatchMessageSenderInfoComRespDto analysisBatchMessageSenderInfoComRespDto = null;
    AnalysisBatchMessageSenderInfoComReqDto analysisBatchMessageSenderInfoComReqDto=new AnalysisBatchMessageSenderInfoComReqDto();
  if(reqDto!=null){
      analysisBatchMessageSenderInfoComReqDto.setSendMsgScene(reqDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1546830_1
analysisBatchMessageSenderInfoComReqDto.setRoleCode(reqDto.getRoleCode());//SimpleFieldAssign//sourceId:1546849_1
analysisBatchMessageSenderInfoComReqDto.setUseScene(reqDto.getUseScene());//SimpleFieldAssign//sourceId:1546831_1
analysisBatchMessageSenderInfoComReqDto.setEntityId(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1546832_1
analysisBatchMessageSenderInfoComReqDto.setIsArchive(reqDto.getIsArchive());//SimpleFieldAssign//sourceId:1546833_1
analysisBatchMessageSenderInfoComReqDto.setSubjectLifeCycle(reqDto.getSubjectLifeCycle());//SimpleFieldAssign//sourceId:1546834_1
    }

    /*D3分析批次内消息发送方身份信息(公共)[8281]   */
    Assert.isNull(analysisBatchMessageSenderInfoComReqDto.getSendMsgScene(),"D3执行预制内容发两人会话消息(公共)-D3分析批次内消息发送方身份信息(公共)-发送消息场景不能为空",false);
      analysisBatchMessageSenderInfoComRespDto = messageService.analysisBatchMessageSenderInfoCom(analysisBatchMessageSenderInfoComReqDto)/*vcase invoke isSameApp*/;




//步骤2: D1-3查询就职记录详情(公共)(边界) - queryInductionRecordDetailComBorder
     QueryInductionRecordDetailComBorderRespDto queryInductionRecordDetailComBorderRespDto = null;
    QueryInductionRecordDetailComBorderReqDto queryInductionRecordDetailComBorderReqDto=new QueryInductionRecordDetailComBorderReqDto();
  queryInductionRecordDetailComBorderReqDto.setIsMainInduction("TRUE");//sourceId:1546807_1
queryInductionRecordDetailComBorderReqDto.setSubjectLifeCycle("CURRENTLY_VALID");//sourceId:1547133_1
if(reqDto!=null){
      queryInductionRecordDetailComBorderReqDto.setOriginalRoleMemberId(reqDto.getReceiveOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546805_1
queryInductionRecordDetailComBorderReqDto.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546813_1
    }

    /*D1-3查消息接收方信息[1340]   */
    Assert.isNull(queryInductionRecordDetailComBorderReqDto.getOriginalRoleMemberId(),"D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-身份人员ID不能为空",false);
Assert.isNull(queryInductionRecordDetailComBorderReqDto.getIsMainInduction(),"D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-是否主岗不能为空",false);
Assert.isNull(queryInductionRecordDetailComBorderReqDto.getSubjectLifeCycle(),"D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-主体生命周期不能为空",false);
Assert.isNull(queryInductionRecordDetailComBorderReqDto.getSpaceId(),"D3执行预制内容发两人会话消息(公共)-D1-3查消息接收方信息-创建于空间ID不能为空",false);
      queryInductionRecordDetailComBorderRespDto = fwBaseInductionRecordClient.queryInductionRecordDetailComBorder(queryInductionRecordDetailComBorderReqDto).getData()/*vcase invoke 跨dubbo调用;*/;




//步骤3: D2生成语义实例故事(公共) - generateSemanticInstanceStoryCom
     GenerateSemanticInstanceStoryComRespDto generateSemanticInstanceStoryComRespDto = null;
    if(analysisBatchMessageSenderInfoComRespDto !=null){
          GenerateSemanticInstanceStoryComReqDto generateSemanticInstanceStoryComReqDto=new GenerateSemanticInstanceStoryComReqDto();
  generateSemanticInstanceStoryComReqDto.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1547134_1
if(reqDto!=null){
      generateSemanticInstanceStoryComReqDto.setTemplateSemanticEngineCode(reqDto.getMsgTitleTemplateSemanticEngineCode());//SimpleFieldAssign//sourceId:1547140_1
    }
if(analysisBatchMessageSenderInfoComRespDto!=null){
      generateSemanticInstanceStoryComReqDto.setFirstFieldValue(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1547135_1
    }

    /*D2生成消息标题语义内容公共)[8234]   */
    Assert.isNull(generateSemanticInstanceStoryComReqDto.getTemplateSemanticEngineCode(),"D3执行预制内容发两人会话消息(公共)-D2生成消息标题语义内容公共)-模板引擎标识不能为空",false);
Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldName(),"D3执行预制内容发两人会话消息(公共)-D2生成消息标题语义内容公共)-第一个字段字段名不能为空",false);
Assert.isNull(generateSemanticInstanceStoryComReqDto.getFirstFieldValue(),"D3执行预制内容发两人会话消息(公共)-D2生成消息标题语义内容公共)-第一个字段字段值不能为空",false);
      generateSemanticInstanceStoryComRespDto = fwCompTemplateEngineClient.generateSemanticInstanceStoryCom(generateSemanticInstanceStoryComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



           }

//步骤4: D2生成语义实例故事(公共) - generateSemanticInstanceStoryCom
     GenerateSemanticInstanceStoryComRespDto generateSemanticInstanceStoryComRespDto_2 = null;
    if(analysisBatchMessageSenderInfoComRespDto !=null){
          GenerateSemanticInstanceStoryComReqDto generateSemanticInstanceStoryComReqDto_1=new GenerateSemanticInstanceStoryComReqDto();
  generateSemanticInstanceStoryComReqDto_1.setTemplateSemanticEngineCode("TWO_PEOPLE_CHAT_DEFAULT_PROMPT_MESSAGE");//CUSTOM_CONVENTION//sourceId:1547148_1
generateSemanticInstanceStoryComReqDto_1.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1547142_1
if(analysisBatchMessageSenderInfoComRespDto!=null){
      generateSemanticInstanceStoryComReqDto_1.setFirstFieldValue(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1547143_1
    }

    /*D2生成“xx”邀请多人加入小岛[8234]   */
    Assert.isNull(generateSemanticInstanceStoryComReqDto_1.getTemplateSemanticEngineCode(),"D3执行预制内容发两人会话消息(公共)-D2生成“xx”邀请多人加入小岛-模板引擎标识不能为空",false);
Assert.isNull(generateSemanticInstanceStoryComReqDto_1.getFirstFieldName(),"D3执行预制内容发两人会话消息(公共)-D2生成“xx”邀请多人加入小岛-第一个字段字段名不能为空",false);
Assert.isNull(generateSemanticInstanceStoryComReqDto_1.getFirstFieldValue(),"D3执行预制内容发两人会话消息(公共)-D2生成“xx”邀请多人加入小岛-第一个字段字段值不能为空",false);
      generateSemanticInstanceStoryComRespDto_2 = fwCompTemplateEngineClient.generateSemanticInstanceStoryCom(generateSemanticInstanceStoryComReqDto_1).getData()/*vcase invoke 跨dubbo调用;*/;



           }

//步骤5: D3分析通道名称缩略图(公共) - analysisChannelNameImageCom
     AnalysisChannelNameImageComRespDto analysisChannelNameImageComRespDto = null;
    if(analysisBatchMessageSenderInfoComRespDto !=null){
          AnalysisChannelNameImageComReqDto analysisChannelNameImageComReqDto=new AnalysisChannelNameImageComReqDto();
  if(reqDto!=null){
      analysisChannelNameImageComReqDto.setSendMsgScene(reqDto.getSendMsgScene());//SimpleFieldAssign//sourceId:1546801_1
analysisChannelNameImageComReqDto.setTableTypeCode(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1546799_1
analysisChannelNameImageComReqDto.setEntityId(reqDto.getNewEntityId());//SimpleFieldAssign//sourceId:1546798_1
analysisChannelNameImageComReqDto.setSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546800_1
    }
if(analysisBatchMessageSenderInfoComRespDto!=null){
      analysisChannelNameImageComReqDto.setSenderOriginalRoleMemberId(analysisBatchMessageSenderInfoComRespDto.getSenderOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546802_1
    }

    /*D3分析通道名称缩略图(公共)[8241]   */
    Assert.isNull(analysisChannelNameImageComReqDto.getSendMsgScene(),"D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-发送消息场景不能为空",false);
Assert.isNull(analysisChannelNameImageComReqDto.getTableTypeCode(),"D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-通道归属主体内容类型编码不能为空",false);
Assert.isNull(analysisChannelNameImageComReqDto.getEntityId(),"D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-通道归属主体内容ID不能为空",false);
Assert.isNull(analysisChannelNameImageComReqDto.getSpaceId(),"D3执行预制内容发两人会话消息(公共)-D3分析通道名称缩略图(公共)-创建于空间ID不能为空",false);
      analysisChannelNameImageComRespDto = messageService.analysisChannelNameImageCom(analysisChannelNameImageComReqDto)/*vcase invoke isSameApp*/;



           }

//步骤6: D3执行消息主题内容分析(公共) - implementMsgThemeContentanAlyseCom
     ImplementMsgThemeContentanAlyseComRespDto implementMsgThemeContentanAlyseComRespDto = null;
    ImplementMsgThemeContentanAlyseComReqDto implementMsgThemeContentanAlyseComReqDto=new ImplementMsgThemeContentanAlyseComReqDto();
  if(reqDto!=null){
      implementMsgThemeContentanAlyseComReqDto.setTableTypeCode(reqDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1546828_1
implementMsgThemeContentanAlyseComReqDto.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1546829_1
    }

    /*D3执行消息主题内容分析(公共)[8129]   */
    Assert.isNull(implementMsgThemeContentanAlyseComReqDto.getTableTypeCode(),"D3执行预制内容发两人会话消息(公共)-D3执行消息主题内容分析(公共)-冗余内容表类型编码不能为空",false);
Assert.isNull(implementMsgThemeContentanAlyseComReqDto.getEntityId(),"D3执行预制内容发两人会话消息(公共)-D3执行消息主题内容分析(公共)-冗余内容表主键ID不能为空",false);
      implementMsgThemeContentanAlyseComRespDto = messageService.implementMsgThemeContentanAlyseCom(implementMsgThemeContentanAlyseComReqDto)/*vcase invoke isSameApp*/;




//步骤7: D2执行全场景两人会话(公共) - implementFullSceneTwoPersonConversationCom
     ImplementFullSceneTwoPersonConversationComRespDto implementFullSceneTwoPersonConversationComRespDto = null;
    if(analysisChannelNameImageComRespDto !=null){
          ImplementFullSceneTwoPersonConversationComReqDto implementFullSceneTwoPersonConversationComReqDto=new ImplementFullSceneTwoPersonConversationComReqDto();
  implementFullSceneTwoPersonConversationComReqDto.setUseChannelMethod("ISHAVE_CHANNEL");//sourceId:1546437_1
implementFullSceneTwoPersonConversationComReqDto.setMessagePromptType("NUMBER_TYPE");//sourceId:1546495_1
implementFullSceneTwoPersonConversationComReqDto.setBorcScene("TOB_SCENE");//sourceId:1546438_1
implementFullSceneTwoPersonConversationComReqDto.setMessageLocationCode("NOTIFICATION_ANNOUNCEMENT");//CUSTOM_CONVENTION//sourceId:1546439_1
implementFullSceneTwoPersonConversationComReqDto.setMsgChannelClassCode("NOTIFICATION_ANNOUNCEMENT");//sourceId:1546442_1
implementFullSceneTwoPersonConversationComReqDto.setChannelTypeCode("PERSONAL_SESSION");//sourceId:1546443_1
implementFullSceneTwoPersonConversationComReqDto.setOperateTime(CommonFunctionHelper.getCurrentTime());//SYSTEM_CURRENT_TIME//sourceId:1546485_1
implementFullSceneTwoPersonConversationComReqDto.setFirstFieldName("idCardName");//CUSTOM_CONVENTION//sourceId:1546487_1
if(reqDto!=null){
      implementFullSceneTwoPersonConversationComReqDto.setPlatformReplace(reqDto.getPlatformReplace());//SimpleFieldAssign//sourceId:1546441_1
implementFullSceneTwoPersonConversationComReqDto.setMessageTemplateCode(reqDto.getMessageTemplateCode());//SimpleFieldAssign//sourceId:1546440_1
implementFullSceneTwoPersonConversationComReqDto.setNewTableTypeCode(reqDto.getNewTableTypeCode());//SimpleFieldAssign//sourceId:1546446_1
implementFullSceneTwoPersonConversationComReqDto.setNewEntityId(reqDto.getNewEntityId());//SimpleFieldAssign//sourceId:1546447_1
implementFullSceneTwoPersonConversationComReqDto.setSurfaceCode(reqDto.getSurfaceCode());//SimpleFieldAssign//sourceId:1546448_1
implementFullSceneTwoPersonConversationComReqDto.setEntityId(reqDto.getEntityId());//SimpleFieldAssign//sourceId:1546449_1
implementFullSceneTwoPersonConversationComReqDto.setChannelSpaceId(reqDto.getSpaceId());//SimpleFieldAssign//sourceId:1546451_1
implementFullSceneTwoPersonConversationComReqDto.setChannelAppId(reqDto.getAppId());//SimpleFieldAssign//sourceId:1546452_1
implementFullSceneTwoPersonConversationComReqDto.setCooperateContentTypeCode(reqDto.getCooperateContentTypeCode());//SimpleFieldAssign//sourceId:1546455_1
implementFullSceneTwoPersonConversationComReqDto.setCooperateContentId(reqDto.getCooperateContentId());//SimpleFieldAssign//sourceId:1546456_1
implementFullSceneTwoPersonConversationComReqDto.setSurfaceContName(reqDto.getSurfaceContName());//SimpleFieldAssign//sourceId:1546457_1
implementFullSceneTwoPersonConversationComReqDto.setMediaType(reqDto.getMediaType());//SimpleFieldAssign//sourceId:1546458_1
implementFullSceneTwoPersonConversationComReqDto.setMediaAddress(reqDto.getMediaAddress());//SimpleFieldAssign//sourceId:1546459_1
implementFullSceneTwoPersonConversationComReqDto.setIsHandle(reqDto.getIsHandle());//SimpleFieldAssign//sourceId:1546460_1
implementFullSceneTwoPersonConversationComReqDto.setHandleType(reqDto.getHandleType());//SimpleFieldAssign//sourceId:1546461_1
implementFullSceneTwoPersonConversationComReqDto.setReferenceMessageId(reqDto.getReferenceMessageId());//SimpleFieldAssign//sourceId:1546462_1
implementFullSceneTwoPersonConversationComReqDto.setMessageContent(reqDto.getMessageContent());//SimpleFieldAssign//sourceId:1546464_1
implementFullSceneTwoPersonConversationComReqDto.setMessageImportantLevel(reqDto.getMessageImportantLevel());//SimpleFieldAssign//sourceId:1546466_1
implementFullSceneTwoPersonConversationComReqDto.setComNumField(reqDto.getComNumField());//SimpleFieldAssign//sourceId:1546484_1
    }
if(analysisChannelNameImageComRespDto!=null){
      implementFullSceneTwoPersonConversationComReqDto.setChannelName(analysisChannelNameImageComRespDto.getChannelName());//SimpleFieldAssign//sourceId:1546444_1
implementFullSceneTwoPersonConversationComReqDto.setChannelLogo(analysisChannelNameImageComRespDto.getChannelLogo());//SimpleFieldAssign//sourceId:1546445_1
    }
if(implementMsgThemeContentanAlyseComRespDto!=null){
      implementFullSceneTwoPersonConversationComReqDto.setThemeContentId(implementMsgThemeContentanAlyseComRespDto.getThemeContentId());//SimpleFieldAssign//sourceId:1546453_1
implementFullSceneTwoPersonConversationComReqDto.setThemeContentTypeCode(implementMsgThemeContentanAlyseComRespDto.getThemeContentTypeCode());//SimpleFieldAssign//sourceId:1546454_1
    }
if(generateSemanticInstanceStoryComRespDto!=null){
      implementFullSceneTwoPersonConversationComReqDto.setMessageTitle(generateSemanticInstanceStoryComRespDto.getObjectName());//SimpleFieldAssign//sourceId:1546463_1
    }
if(generateSemanticInstanceStoryComRespDto_2!=null){
      implementFullSceneTwoPersonConversationComReqDto.setNewMessage(generateSemanticInstanceStoryComRespDto_2.getObjectName());//SimpleFieldAssign//sourceId:1546465_1
    }
if(analysisBatchMessageSenderInfoComRespDto!=null){
      implementFullSceneTwoPersonConversationComReqDto.setIsAssistant(analysisBatchMessageSenderInfoComRespDto.getIsAssistant());//SimpleFieldAssign//sourceId:1546467_1
implementFullSceneTwoPersonConversationComReqDto.setMessageRole(analysisBatchMessageSenderInfoComRespDto.getMessageRole());//SimpleFieldAssign//sourceId:1546468_1
implementFullSceneTwoPersonConversationComReqDto.setSenderDeptId(analysisBatchMessageSenderInfoComRespDto.getSenderDeptId());//SimpleFieldAssign//sourceId:1546469_1
implementFullSceneTwoPersonConversationComReqDto.setSenderVirtualOrgMemberId(analysisBatchMessageSenderInfoComRespDto.getSenderVirtualOrgMemberId());//SimpleFieldAssign//sourceId:1546470_1
implementFullSceneTwoPersonConversationComReqDto.setSenderInductionRecordId(analysisBatchMessageSenderInfoComRespDto.getSenderInductionRecordId());//SimpleFieldAssign//sourceId:1546471_1
implementFullSceneTwoPersonConversationComReqDto.setSenderOriginalRoleMemberId(analysisBatchMessageSenderInfoComRespDto.getSenderOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546472_1
implementFullSceneTwoPersonConversationComReqDto.setSenderUserId(analysisBatchMessageSenderInfoComRespDto.getSenderUserId());//SimpleFieldAssign//sourceId:1546473_1
implementFullSceneTwoPersonConversationComReqDto.setNameOfSender(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1546474_1
implementFullSceneTwoPersonConversationComReqDto.setSenderProfilePictureAddress(analysisBatchMessageSenderInfoComRespDto.getSenderProfilePictureAddress());//SimpleFieldAssign//sourceId:1546475_1
implementFullSceneTwoPersonConversationComReqDto.setSenderSpaceId(analysisBatchMessageSenderInfoComRespDto.getSenderSpaceId());//SimpleFieldAssign//sourceId:1546476_1
implementFullSceneTwoPersonConversationComReqDto.setSenderAppId(analysisBatchMessageSenderInfoComRespDto.getSenderAppId());//SimpleFieldAssign//sourceId:1546477_1
implementFullSceneTwoPersonConversationComReqDto.setSmsBehaviorType(analysisBatchMessageSenderInfoComRespDto.getSmsBehaviorType());//SimpleFieldAssign//sourceId:1546486_1
implementFullSceneTwoPersonConversationComReqDto.setFirstFieldValue(analysisBatchMessageSenderInfoComRespDto.getNameOfSender());//SimpleFieldAssign//sourceId:1546488_1
    }
if(queryInductionRecordDetailComBorderRespDto!=null){
      implementFullSceneTwoPersonConversationComReqDto.setReceiveProfilePictureAddress(queryInductionRecordDetailComBorderRespDto.getUserFace());//SimpleFieldAssign//sourceId:1546478_1
implementFullSceneTwoPersonConversationComReqDto.setNameOfReceive(queryInductionRecordDetailComBorderRespDto.getIdCardName());//SimpleFieldAssign//sourceId:1546479_1
implementFullSceneTwoPersonConversationComReqDto.setReceiveOriginalRoleMemberId(queryInductionRecordDetailComBorderRespDto.getOriginalRoleMemberId());//SimpleFieldAssign//sourceId:1546480_1
implementFullSceneTwoPersonConversationComReqDto.setReceiveUserId(queryInductionRecordDetailComBorderRespDto.getUserId());//SimpleFieldAssign//sourceId:1546481_1
implementFullSceneTwoPersonConversationComReqDto.setRoleMemberCode(queryInductionRecordDetailComBorderRespDto.getRoleMemberCode());//SimpleFieldAssign//sourceId:1546496_1
implementFullSceneTwoPersonConversationComReqDto.setPhone(queryInductionRecordDetailComBorderRespDto.getPhone());//SimpleFieldAssign//sourceId:1546497_1
implementFullSceneTwoPersonConversationComReqDto.setReceiveSpaceId(queryInductionRecordDetailComBorderRespDto.getSpaceId());//SimpleFieldAssign//sourceId:1546482_1
implementFullSceneTwoPersonConversationComReqDto.setReceiveAppId(queryInductionRecordDetailComBorderRespDto.getAppId());//SimpleFieldAssign//sourceId:1546483_1
    }

    /*D2执行全场景两人会话(公共)[8260]   */
    Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getUseChannelMethod(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-使用通道方式不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessagePromptType(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息提示类型不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getBorcScene(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-toB或toC场景不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageLocationCode(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息位置标识不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMsgChannelClassCode(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息使用通道类别不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getPlatformReplace(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-是否平台代操作不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelTypeCode(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道类型编码不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageTemplateCode(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息模板标识不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelName(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道名称不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelLogo(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道缩略图地址不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNewTableTypeCode(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属主体内容类型编码不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNewEntityId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属主体内容ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSurfaceCode(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-归属内容类型编码不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getEntityId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-归属内容ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelSpaceId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属空间ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getChannelAppId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通道归属联盟应用ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getHandleType(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-处理类型不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageContent(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息内容不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageImportantLevel(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-消息重要紧急度层级不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getIsAssistant(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方是否助手不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getMessageRole(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方角色不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderOriginalRoleMemberId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方身份人员ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderUserId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方账号ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNameOfSender(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方姓名不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderProfilePictureAddress(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方头像地址不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderSpaceId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方空间ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getSenderAppId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-发送方联盟应用ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveProfilePictureAddress(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方头像地址不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getNameOfReceive(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方姓名不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveOriginalRoleMemberId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方身份人员ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveUserId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方账号ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveSpaceId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方空间ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getReceiveAppId(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-接收方联盟应用ID不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getComNumField(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-通用数值字段（整数型）不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getOperateTime(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-操作时间不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getFirstFieldName(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-第一个字段字段名不能为空",false);
Assert.isNull(implementFullSceneTwoPersonConversationComReqDto.getFirstFieldValue(),"D3执行预制内容发两人会话消息(公共)-D2执行全场景两人会话(公共)-第一个字段字段值不能为空",false);
      implementFullSceneTwoPersonConversationComRespDto = fwCompMessageClient.implementFullSceneTwoPersonConversationCom(implementFullSceneTwoPersonConversationComReqDto).getData()/*vcase invoke 跨dubbo调用;*/;



           }

ImplementPrefabricateContentSendTwoPersonConvMsgComRespDto retData = new ImplementPrefabricateContentSendTwoPersonConvMsgComRespDto();





return retData;
  }
  //
}
